from airflow.operators.bash import BashOperator

from jms.time_sensor import time_after_05_00

jms_ai__sync_geo_info_day = BashOperator(
    task_id='jms_ai__sync_geo_info_day',
    email=['yushuo@jtexpress.com','yl_bigdata@yl-scm.com'],
    bash_command="jms/aigroup/ai_group/sync_geo_info_day/execute.sh",
    pool='unlimited_pool',
    yarn_queue='pyspark',
    priority_weight=0,
)

jms_ai__sync_geo_info_day << time_after_05_00
